// 导入mysql包
const mysql = require('mysql');
// 导入配置
const option = require('./database');
// 使用连接池
const pool = mysql.createPool(option.mysql);
// 使用promise
module.exports = {
    //调用query方法执行sql语句
    query: function (sql) {
        // 返回操作数据库的promise
        return new Promise((resolve, reject) => {
            // 连接数据库
            pool.getConnection(function (err, connection) {
                // console.log('1.0',connection);// 1.0 undefined 检查数据库配置
                // 执行sql语句
                connection.query(sql, function (err, rows) {
                    // console.log(err,rows);// err: null 执行正常   ；  rows： 执行结果
                    // 操作失败
                    if(err!=null){
                        // 如果err有值 就表示执行出现异常
                        reject(err)
                    }
                    // 操作成功
                    else {
                        resolve(rows);
                    }
                    // 释放连接
                    connection.release();
                })
            })
        })
    }
}